package com.enjoyor.soa.traffic.api.service.dubbo.bigdata;

import com.alibaba.fastjson.JSONObject;
import com.enjoyor.soa.traffic.util.pojo.ResultPojo;

import java.util.List;

/**
 *	kafka读写服务，以支持华为安全/非安全模式
 *
 * @author Administrator
 */
public interface DubboKafkaService {

    /**
	 * 发送消息
	 * @param topic
     * @param msg
	 * @return
	 */
    public ResultPojo sendJSONMsg(String topic, JSONObject msg);
    /**
     * 发送消息
     * @param topic
     * @param msg
     * @return
     */
    public ResultPojo sendStrMsg(String topic, String msg);


    /**
     * 读取kafka消息
     * @param topic
     * @param groupId
     * @return List<JSONObject>
     */
    ResultPojo pollJSONMsg(String topic, String groupId);
    /**
     * 读取kafka消息
     * @param topic
     * @param groupId
     * @return List<String>
     */
    ResultPojo pollStrMsg(String topic, String groupId);


}
